#set( $symbol_pound = '#' )
#set( $symbol_dollar = '$' )
#set( $symbol_escape = '\' )
package ${package}.domain.xxx.service.Impl;

import ${package}.domain.xxx.adapter.IMqServiceAdapter;
import ${package}.domain.xxx.service.IMqTest;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;

@Service("mqTest")
public class MqTest implements IMqTest {

    @Resource
    private IMqServiceAdapter mqServiceAdapter;

    @Override
    public void testSendMqMessage() {
        mqServiceAdapter.sendMessage("test-topic", "sendMessage" + LocalDateTime.now());
        mqServiceAdapter.sendOneWayMessage("test-topic", "syncSendMessage" + LocalDateTime.now());
        mqServiceAdapter.syncSendMessage("test-topic", "syncSendMessage" + LocalDateTime.now());
        mqServiceAdapter.asyncSendMessage("test-topic", "asyncSendMessage" + LocalDateTime.now());
    }
}
